package cn.itsource._01_helloworld;

import cn.itsource.ConnectionUtil;
import com.rabbitmq.client.Channel;
import com.rabbitmq.client.Connection;

//发送消息
public class Send {

    public static final String NAME_QUEUE_HELLOWORLD = "name_queue_helloworld";

    public static void main(String[] args) throws Exception {
        //建立连接对象
        Connection connection = ConnectionUtil.getConnection();
        //建立通道
        Channel channel = connection.createChannel();
        //交换机使用默认的
        //声明队列
        /**
         * 声明队列，如果Rabbit中没有此队列将自动创建
         * param1:队列名称
         * param2:是否持久化
         * param3:队列是否独占此连接
         * param4:队列不再使用时是否自动删除此队列
         * param5:队列参数
         */

        channel.queueDeclare(NAME_QUEUE_HELLOWORLD,true,false,false,null);
        //发送消息
        //准备消息
        String message = "hello world message...";
        channel.basicPublish("",NAME_QUEUE_HELLOWORLD,null,message.getBytes());
        System.out.println("消息发送完毕"+message);

    }




}
